var express = require('express');
var fs = require('fs');
var mysql = require('mysql');
var ejs = require('ejs');
var router = express.Router();
//连接MySQL数据库
var client = mysql.createConnection({
  host: 'localhost',
  port:"3306",
  user: 'root',
  password: '123456',
  database: 'test'
});

//显示用户列表
router.get('/', function (request, response) {
   console.log(request.body);
   client.query('select * from user', function (error, results) {
   response.render('user/user-list.ejs', {
  data: results
   });
  });
  });
  
  //一个用于处理获取添加用户页面的 GET 请求，另一个用于处理实际添加用户数据的 POST 请求，共同完成添加用户的功能流程。
  //处理获取添加用户页面的路由（GET 请求）

  //客户端向服务器发送一个 GET 请求，且请求路径为 /add，服务器就会匹配到这个路由，并执行对应的处理函数。
  router.get('/add', function (request, response) {
   //读取模板文件
  response.render('user/user-add.ejs');
  });
  //添加处理逻辑
  //处理用户在添加用户页面填写好信息后提交表单所发起的 POST 请求
  router.post('/add', function (request, response) {
  //声明body
   var body = request.body;
   //执行SQL语句
   client.query('insert into user (id,username,password,nikename) VALUES ( ?, ?, ? ,?)', [
  body.id,body.username,body.password, body.nikename
  ], function () {
  //响应信息
  response.redirect('/user');
   });
  });
  
  router.get('/edit/:id', function (request, response) {
  console.log(request.params.id);
  client.query('select * from user where id =?', [
   request.params.id
  ], function (error, result) {
   console.log(result);
  response.render('user/user-edit.ejs', {
   data: result[0]
   });
   });
  });
  
  
  router.post('/edit/:id', function (request, response) {
  //声明body
  var body = request.body;
  console.log(body);
  //执行SQL语句
  client.query('update user set nikename=? where username=?',
  [body.nikename, body.username], function () {
  //响应信息
  response.redirect('/user');
  });
  });
  
  router.get('/delete/:id', function (request, response) {
  //执行SQL语句
   client.query('delete from user where id=?', [request.params.id], function () {
  //响应信息
  response.redirect('/user');
   });
  });
  module.exports = router;
  